package com.caption.mq.entity;

import lombok.Data;

import java.util.Date;

@Data
public class MqSubscribeDO {
    /**
     * 消费者组
     */
    private String consumerId;

    /**
     * 请求方式
     */
    private String httpMethod;

    private String group;
    private String topic;
    private String tag;
    /**
     * 最大重试次数，超过最大重试次数，消息将被转 移到私信队列
     */
    private Integer retryCount;
    /**
     * 消息重新策略 0-每隔5秒重试， 1-重试时间按 1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10m 20m 30m 1h 2h 增加
     */
    private Integer failRetryStrategy;

    /**
     * 消费线程池最大线程数
     */
    private Integer consumeThreadMax;
    /**
     * 消费组group生成最小线程数
     */
    private Integer consumeThreadMin;
    /**
     * 批量拉取数据，一次从broker拉取消息条数
     */
    private Integer pullBatchSize;
    /**
     * 消费端批量消费每次处理消息条数
     */
    private Integer consumeMessageBatchMaxSize;
    /**
     * 新添加的组从哪里开始消费 0-从最新的开始 1-从头开始 2-从某一个时间开始
     */
    private Integer consumeFromWhere;
    /**
     * 当前消费时间， 当consumeFromWhere=2，取从这个时间开始进行消费.
     */
    private Date consumeFromTime;
    /**
     * 消费方式 0 集群消费 1 顺序消息
     */
    private Integer consumeMode;
}
